package cn.techfan.customerserviceconsole;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.integration.annotation.InboundChannelAdapter;

@EnableBinding(Source.class)
public class CustomerPublisher {
    @InboundChannelAdapter(channel = Source.OUTPUT)
    public String sendToChannel(){
        return "{\"Message from Spring Cloud Stream\": \"Michael in Shenzhen. PR.China\"}";
    }
}
